# -*- coding: utf-8 -*-
from utils.redis import Redis
r = Redis.r
result = r.xreadgroup("g1", 'c1', {"stream.order": '0'}, count=1, block=2000)
print(result)